package cn.iocoder.yudao.module.forward.mqtt;

public class MqttConstants {
    public static final String THREAD_POOL_MQTT_RECONNECT = "mqtt_reconnect";
    public static final Integer KEEPALIVE_FORWARD = 60;
    public static final Integer KEEPALIVE_BROKER = 60;

    public static final Integer STATUS_CONNECTED = 1;
    public static final Integer STATUS_DISCONNECTED = 0;

    public static final Integer MQTT_QOS_0 = 0;
    public static final Integer MQTT_QOS_1 = 1;
    public static final Integer MQTT_QOS_2 = 2;

    public static final Integer MQTT_QOS = MQTT_QOS_2;

    public static final String TOPIC_TYPE_EEW = "eew";
    public static final String TOPIC_TYPE_EQR = "eqr";
    public static final String TOPIC_TYPE_ACK = "ack";
    public static final String TOPIC_TYPE_ACK2 = "ack2";

    public static final String MSG_NORMAL = "0101";//普通预警消息
    public static final String MSG_MAJOR = "0102";//专业预警消息
    public static final String MSG_CANCEL = "0199";//预警事件取消消息
    public static final String MSG_NORMAL_EXERCISE = "0201";//普通预警演习消息
    public static final String MSG_MAJOR_EXERCISE = "0202";//专业预警演习消息
    public static final String MSG_NORMAL_TEST = "0301";//普通预警测试消息
    public static final String MSG_MAJOR_TEST = "0302";//专业预警测试消息
    public static final String MSG_FAST_TEST = "0303";//速报测试信息
    public static final String MSG_FAST_AUTO = "0401";//自动速报信息
    public static final String MSG_FAST_FORMAL = "0402";//正式速报信息
}
